/** 
* @version:1.0.1
* @Description: （对类进行功能描述）
* @author: yangdechao
* @date: datedate 2021年11月15日 下午3:35:42
*/
package cn.com.guage.flink.partitioner;

import org.apache.flink.api.common.functions.Partitioner;

/**
 * @version:1.0.1
 * @Description: （对类进行功能描述）
 * @author: yangdechao
 * @param <K>
 * @date: datedate 2021年11月15日 下午3:35:42
 */
public class MyPartition implements Partitioner<String> {
	/**
	 * 
	 */
	private static final long serialVersionUID = 1502894562620729972L;

	@Override
	public int partition(String key, int numPartitions) {
		if ("杨得朝".equals(key)) {
			return 0;
		}
		if ("孟彩霞".equals(key)) {
			return 1;
		} else {
			return 2;
		}
	}
}
